982501a5ed2c5b0eb55a24a87e98bd871c59068a,src/test/java/net/jodah/failsafe/ListenerConfigTest.java,ListenerConfigTest,bindListeners,#SyncFailsafe#,114
Before Change
failsafe.onComplete((r, f) -> complete.incrementAndGet());
failsafe.onComplete((r, f, s) -> ctxComplete.incrementAndGet());
failsafe.onCompleteAsync((r, f) -> {
asyncComplete.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onCompleteAsync((r, f, s) -> {
asyncCtxComplete.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onAbort(e -> abort.incrementAndGet());
failsafe.onAbort((r, e) -> abortResult.incrementAndGet());
failsafe.onAbort((r, e, c) -> ctxAbort.incrementAndGet());
failsafe.onAbortAsync(e -> {
asyncAbort.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onAbortAsync((r, e) -> {
asyncAbortResult.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onAbortAsync((r, e, c) -> {
asyncCtxAbort.incrementAndGet();
waiter.resume();
} , executor);
failsafe.onFailure(e -> failure.incrementAndGet());
failsafe.onFailure((r, f) -> failureResult.incrementAndGet());
failsafe.onFailure((r, f, s) -> ctxFailure.incrementAndGet());
failsafe.onFailureAsync(e -> asyncFailure.incrementAndGet(), executor);
failsafe.onFailureAsync((r, f) -> asyncFailureResult.incrementAndGet(), executor);
failsafe.onFailureAsync((r, f, s) -> asyncCtxFailure.incrementAndGet(), executor);
failsafe.onSuccess((r) -> success.incrementAndGet());
failsafe.onSuccess((r, s) -> ctxSuccess.incrementAndGet());
After Change
failsafe.onAbort((r, e, c) -> abort.sync(3));
failsafe.onAbortAsync(e -> abort.async(4), executor);
failsafe.onAbortAsync((r, e) -> abort.async(5), executor);
failsafe.onAbortAsync((r, e, c) -> abort.async(6), executor);
abort.asyncListeners = 3;
failsafe.onComplete((r, f) -> complete.sync(1));
failsafe.onComplete((r, f, s) -> complete.sync(2));
failsafe.onCompleteAsync((r, f) -> complete.async(3), executor);
failsafe.onCompleteAsync((r, f, c) -> complete.async(4), executor);
complete.asyncListeners = 2;
failsafe.onFailedAttempt(e -> failedAttempt.sync(1));
failsafe.onFailedAttempt((r, f) -> failedAttempt.sync(2));
failsafe.onFailedAttempt((r, f, c) -> failedAttempt.sync(3, c));
failsafe.onFailedAttemptAsync(e -> failedAttempt.async(4), executor);
failsafe.onFailedAttemptAsync((r, f) -> failedAttempt.async(5), executor);
failsafe.onFailedAttemptAsync((r, f, c) -> failedAttempt.async(6, c), executor);
failedAttempt.asyncListeners = 3;
failsafe.onFailure(e -> failure.sync(1));
failsafe.onFailure((r, f) -> failure.sync(2));
failsafe.onFailure((r, f, s) -> failure.sync(3));
failsafe.onFailureAsync(e -> failure.async(4), executor);
failsafe.onFailureAsync((r, f) -> failure.async(5), executor);
failsafe.onFailureAsync((r, f, s) -> failure.async(6), executor);
failure.asyncListeners = 3;
failsafe.onRetriesExceeded(e -> retriesExceeded.sync(1));
failsafe.onRetriesExceeded((r, f) -> retriesExceeded.sync(2));
failsafe.onRetriesExceededAsync(e -> retriesExceeded.async(3), executor);
failsafe.onRetriesExceededAsync((r, f) -> retriesExceeded.async(4), executor);
retriesExceeded.asyncListeners = 2;
failsafe.onRetry(e -> retry.sync(1));